package Blood.SqlParse

import org.apache.flink.api.scala.{DataSet, ExecutionEnvironment}
import org.apache.flink.api.scala._
object stream {
  def main(args: Array[String]): Unit = {
    val env = ExecutionEnvironment.getExecutionEnvironment
    //网站排名的案例
    //    定义用户类型
    case class Link(sourceId: Long, targetId: Long)
    //  读取csv文件的逻辑
    val page_path = "file:\\C:\\Users\\YH\\Desktop\\data.txt"
//    env.readCsvFile(page_path)
    //读取页面和原始的排名 通过解析CSV 文件
    val link_path = "file:\\C:\\Users\\YH\\Desktop\\link.txt"
//    val pages = fromCsv(env, page_path)
//    val out = fromCsv(env,page_path)

    env.execute()
  }

}



